package com.hudson.broker.consumer;

import io.netty.channel.ChannelHandlerContext;

/**
 * @Author: 渔小鲤
 * @DateTime: 2025/7/8 21:24
 **/
public class PullRequest {

    private ChannelHandlerContext ctx;

    private String consumerGroup;
    private String topic;
    private int queueId;

    private long createTime;


    public PullRequest(ChannelHandlerContext ctx, String consumerGroup, String topic, int queueId, long createTime) {
        this.ctx = ctx;
        this.consumerGroup = consumerGroup;
        this.topic = topic;
        this.queueId = queueId;
        this.createTime = createTime;
    }

    public String getConsumerGroup() {
        return consumerGroup;
    }

    public void setConsumerGroup(String consumerGroup) {
        this.consumerGroup = consumerGroup;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public int getQueueId() {
        return queueId;
    }

    public void setQueueId(int queueId) {
        this.queueId = queueId;
    }

    public ChannelHandlerContext getCtx() {
        return ctx;
    }

    public void setCtx(ChannelHandlerContext ctx) {
        this.ctx = ctx;
    }

    public long getCreateTime() {
        return createTime;
    }

    public void setCreateTime(long createTime) {
        this.createTime = createTime;
    }
}
